package com.xiaomaoguai;

import com.zhongan.blcs.client.DBEvent;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;

/**
 * @author WeiHui-Z
 * @version v1.0.0
 * @date 2019/8/30 20:37
 * @since JDK 1.8
 */
public class BlcsSinkToMySQL implements SinkFunction<DBEvent> {

	@Override
	public void invoke(DBEvent value, Context context) throws Exception {

	}

}
